package com.zhouchb.kafkaspring_boot.consumer;

import org.springframework.context.annotation.Configuration;
import org.springframework.kafka.annotation.KafkaListener;

/**
 * @Create 2023-05-03 20:25
 * @Description
 */
@Configuration
public class KafkaConsumer {
    @KafkaListener(topics = "first",groupId = "test01")
    public void msgConsumer(String msg){
        System.out.println(msg);
    }
}
